package com.zt.bigdata.spark.common.dto

import java.sql.Timestamp

/**
  *
  */
case class StreamRecord[E](topic: String, timestamp: Timestamp, body: E) extends Serializable